5519f80abba5d42ae5a6d69b9659c596fd8717eb,src/test/java/org/elasticsearch/test/integration/recovery/RelocationTests.java,RelocationTests,testSimpleRelocationNoIndexing,#,62

Before Change


                .add(new MoveAllocationCommand(new ShardId("test", 0), "node1", "node2"))
                .execute().actionGet();

        clusterHealthResponse = client("node1").admin().cluster().prepareHealth().setWaitForRelocatingShards(0).execute().actionGet();
        assertThat(clusterHealthResponse.timedOut(), equalTo(false));
        clusterHealthResponse = client("node2").admin().cluster().prepareHealth().setWaitForRelocatingShards(0).execute().actionGet();
        assertThat(clusterHealthResponse.timedOut(), equalTo(false));

        logger.info("--> verifying count again...");

After Change


                .add(new MoveAllocationCommand(new ShardId("test", 0), "node1", "node2"))
                .execute().actionGet();

        clusterHealthResponse = client("node1").admin().cluster().prepareHealth().setWaitForRelocatingShards(0).setTimeout(ACCEPTABLE_RELOCATION_TIME).execute().actionGet();
        assertThat(clusterHealthResponse.timedOut(), equalTo(false));
        clusterHealthResponse = client("node2").admin().cluster().prepareHealth().setWaitForRelocatingShards(0).setTimeout(ACCEPTABLE_RELOCATION_TIME).execute().actionGet();
        assertThat(clusterHealthResponse.timedOut(), equalTo(false));

        logger.info("--> verifying count again...");